package com.baijiaoxi.common.model.asyncjob.eventbus;

import com.baijiaoxi.common.model.mq.MQBody;
import com.google.common.eventbus.Subscribe;


public interface EventBusSubscriber {
    /**
     * 注意加上@Subscribe注解
     *
     * @param mqBody
     */
    @Subscribe
    void handleEvent(MQBody mqBody);

    String topic();

    int poolSize();
}
